package net.wicp.tams.common.binlog.self.sender.impl;

import java.util.Map;

import com.alibaba.fastjson.JSONObject;

import net.wicp.tams.common.Result;
import net.wicp.tams.common.binlog.self.bean.SendBean;
import net.wicp.tams.common.binlog.self.bean.SendObj;
import net.wicp.tams.common.binlog.self.sender.AbsSender;

public class LogFile extends AbsSender {

	@Override
	public void initSub(Map<String, String> params) {
	}

	@Override
	public Result sendMsgSub(SendBean sendBean) {
		SendObj sendobj = sendBean.toSendObj();
		log.info("库：{},表：{}，操作：{},gtid:{}, 值：{}", sendobj.getDb(), sendobj.getTb(), sendBean.getOptType().name(),
				sendBean.getGtid(), JSONObject.toJSONString(sendobj.getRows()));
		log.info("增：{}  删：{}  改：{}", insertNum, deleteNum, updateNum);
		return Result.getSuc();
	}

}
